package com.hexinfo.dmpro.sparing.service;


import cn.hutool.core.io.file.FileAppender;
import com.hexinfo.dmpro.sparing.dto.DateDataDTO;

import java.util.concurrent.Future;

/**
 * DistCP操作类
 * 针对所有java调用sh脚本启动DistCP方式
 *
 */
public interface AsyncDateDataService {

    Future<Boolean> execSql(DateDataDTO dateDataDTO, String source, int sizes, FileAppender heatlog, String tbLogPath);

    void updateEndFlag(String souName,Boolean state);

    Boolean getEndFlag(String souName);

    void deleteEndFlag(String souName);

    void updateTaskState(String souName,Boolean state);

    Boolean getTaskState(String souName);

    void deleteTaskState(String souName);

}
